const Mysql = require('mysql')

class Db{
    constructor() {
    }
    connectSql(){
        let mysql = Mysql.createConnection({
            host: 'localhost',
            user: 'root',
            password: '123456',
            database:'pin_san_zhang'
        })
        mysql.connect();
        this._mysql = mysql;
        console.log('db.js-->>数据库连接成功');
    }

    //自己封装的mysql方法负责查询   sql：sql语句, resolve: 查询成功的回调函数  reject：查询失败的回调函数
    myQuery(sql,resolve,reject){
        this._mysql.query(sql,(err,result)=>{
            if(err){
                reject(err);
            }else{
                resolve(result)
            }
        })
    }
}

//导出此模块
module.exports = Db;